package com.tcs.kafka.producer.sender.balance;

import com.tcs.kafka.producer.sender.SenderBalance;

/**
* @Title: ITopicPartition.java
* @Package com.tcs.kafka.producer.sender.balance
* @author 神经刀
* @date 2018年10月15日
* @version V1.0
 */
public interface ITopicPartition {
	
	/**
	* @Title: getSizeByTopic  
	* @Description: 根据topic或者分区个数
	* @param @param topic
	* @return Integer    返回类型  
	 */
	Integer getSizeByTopic(String topic);

	/**
	* @Title: getParititon  
	* @Description: 根据负载类型获取分区 
	* @param @param SenderBalance
	* @param topic : 主题
	* @return Integer    返回类型  
	 */
	Integer getParititon(String topic , SenderBalance SenderBalance);
}